package com.fyyg.wechat.util.message;

import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;

import com.fyyg.common.messagequeue.MessageQueuManage;

/**
 * 消息监听器 
 * @author XLM  2016年3月18日
 *
 */
public class ConsumerMessageListener implements MessageListener {

	@Override
	public void onMessage(Message message) {
		//这里我们知道生产者发送的就是一个纯文本消息，所以这里可以直接进行强制转换，或者直接把onMessage方法的参数改成Message的子类TextMessage  
        TextMessage textMsg = (TextMessage) message;   
        try {   
        	System.out.println("触发消息队列"+message);
            MessageQueuManage.messageQueuManage(textMsg.getText());
        } catch (Exception e) {   
            e.printStackTrace();   
        }   
        
	}

}
